package com.ydl.learning.flink.demo.pipeline.java.impl;

import com.ydl.learning.flink.demo.pipeline.java.Init;
import org.apache.flink.streaming.api.datastream.DataStream;

/**
 *
 */
public class TubeStreamSourceInitImpl extends BaseProcedureImpl implements Init<String> {

  /**
   * Default constructor
   */
  public TubeStreamSourceInitImpl() {
  }

  /**
   *
   */
  @Override
  public DataStream<String> init() {
    // TODO implement here
    return null;
  }

}